package csl.blog.server.mq.consumer.service;

import cn.hutool.json.JSONObject;
import com.baomidou.mybatisplus.extension.service.IService;
import com.rabbitmq.client.Channel;
import csl.blog.server.mq.consumer.entity.AsyncEventEntity;

import java.io.IOException;

public interface AsyncEventService extends IService<AsyncEventEntity> {

    void receiveEvent(JSONObject message, long deliveryTag, Channel channel) throws IOException;

    boolean handleRepeat(String cacheKey, String taskId, String taskTag, JSONObject content);

    boolean handleMessage(JSONObject message);
}
